package com.ass.rocketmq.base;

import lombok.extern.log4j.Log4j2;
import org.apache.rocketmq.client.consumer.AllocateMessageQueueStrategy;
import org.apache.rocketmq.common.message.MessageQueue;

import java.util.List;

//消息息队列分配策略。如果传递null，将使用默认的分配策略 消费者端
//todo 待实现
@Log4j2
public abstract class AbstractAllocateMessageQueueStrategy implements AllocateMessageQueueStrategy {


    @Override
    public List<MessageQueue> allocate(String consumerGroup, String currentCID,
                                       List<MessageQueue> mqAll, List<String> cidAll) {
        return mqAll;
    }

    @Override
    public String getName() {
        return null;
    }
}
